package com.iot.websocket;

import com.iot.common.constant.EqConstants;
import com.iot.common.utils.spring.SpringUtils;
import com.iot.websocket.message.MqttClientMessage;

/**
 * @author Cao.ning
 * @date 2022/6/27
 */
public class WebSocketMessagePublisher {

    public static void publish(MqttClientMessage message){
        if(message != null){
//            KesonMqttCallback kesonMqttCallback = SpringUtils.getBean(KesonMqttCallback.class);
//            kesonMqttCallback.publish(message.getTopic(), EqConstants.qos, message.dataString());
        }
    }
}
